package com.demo.flink;

import com.plat.paas.kafka.Message;
import org.apache.flink.streaming.api.functions.sink.SinkFunction;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

/**
 * @author : pengjie
 * @PackageName : com.demo.flink
 * @Description : TODO
 * @email : 627799251@qq.com
 * @Date : 2019/1/30 16:44
 */
public class KafkaSink implements SinkFunction<Message> {
    private Logger logger = LoggerFactory.getLogger(KafkaSink.class);
    @Override
    public void invoke(Message value, Context context) throws Exception {
        logger.info("receive msg = " + value.toString());
    }
}
